#include "enviadormensagem.h"
#include "participante.h"

EnviadorMensagem::EnviadorMensagem(Participante* conexao) : QThread()
{
    this->conexao = conexao;
    connect(this, SIGNAL(enviarMensagem(Mensagem*)), this->conexao, SLOT(sendMessage(Mensagem*)));
}

void EnviadorMensagem::run()
{
    while (true) {
        if (!this->conexao->mensagens.isEmpty()) {
            emit this->enviarMensagem(this->conexao->mensagens.takeFirst());
            this->sleep(1);
        }
    }
}
